package com.iussoft.receiveData.kafka;

import com.apache.exception.ServiceException;
import com.iussoft.tools.LoggerUtil;
import com.iussoft.tools.UnityErrorCode;
import org.springframework.util.concurrent.FailureCallback;

/**
 * @description: //失败业务逻辑
 * @author: Hou Dayu
 * @date: Created in 2020/3/1
 */
public class KafakMsgCallback implements FailureCallback {

    @Override
    public void onFailure(Throwable ex) {
        LoggerUtil.error("发送kafka数据失败",ex);
        throw new ServiceException(UnityErrorCode.SEND_KAFKA.getDesc());
    }
}

